package code.web.websocket;

import org.springframework.stereotype.Component;

import javax.websocket.OnClose;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/chat2") // 注意路径前缀
@Component // 必须标记为Spring组件
public class ChatEndpoint {

    // 连接建立回调
    @OnOpen
    public void onOpen(Session session) {
        System.out.println("连接建立: " + session.getId());
    }

    // 接收消息回调
    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("收到消息: " + message);
    }

    // 连接关闭回调
    @OnClose
    public void onClose(Session session) {
        System.out.println("连接关闭: " + session.getId());
    }
}